package com.ziyucoding.springboot.labs.lab3.sca.rocketmqdemo.dtp.listener;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * 订单 Sink
 *
 * @author ziyucoding
 * @date 2023-04-03
 **/
public interface OrderSink {

    String ORDER_INPUT = "order-input";

    @Input(ORDER_INPUT)
    SubscribableChannel orderInput();
}
